package org.example.flink.source;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

import java.util.Arrays;
import java.util.List;


/**
 * @Author: tang
 * @Description:
 * @Date 2025/2/16 01:14
 */
public class FlinkSourceCollection {

    public static void main(String[] args) throws Exception{
        StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();
        List<Integer> data = Arrays.asList(1, 22, 3);
        environment.fromCollection(data).print();
        environment.execute();
    }

}
